package streaming

import org.apache.spark.streaming.{Seconds, StreamingContext}
import org.apache.spark.{SparkConf, SparkContext}

object SparkStreamingJoin {
  def main(args: Array[String]): Unit = {
    val sparkconf=new SparkConf().setMaster("localhost[*]").setAppName("join")
    //RDD的环境
    //    val ssc=new SparkContext(sparkconf)
    //Streaming环境
    val ssc=new StreamingContext(sparkconf,Seconds(3))
  }

}
